package cn.com.bluemoon.bd.flink.udf;

import org.apache.flink.table.api.TableEnvironment;

/**
 * @author 刘天能
 * @createAt 2020-08-11 11:55
 * @description 注册udf函数
 */
public class UdfRegister {
    public static void register(TableEnvironment tableEnv) {
        tableEnv.createTemporaryFunction("plus8hour", new Plus8hour());
        tableEnv.createTemporaryFunction("curTimeMills", new CurTimeMillsUDF());
        tableEnv.createTemporaryFunction("f_date_add", new DateAdd());
        tableEnv.createTemporaryFunction("f_nvl", new FNvl());
    }
}
